package com.fulu.game.bigdata.realtime.entity

import java.util

import scala.beans.BeanProperty

class Sink extends Serializable{

  @BeanProperty var sinkType:String = _
  @BeanProperty var sinkTable : String = _
  @BeanProperty var kafkaTopic: String =_
  @BeanProperty var esIndex: String =_
  @BeanProperty var esType: String =_
  @BeanProperty var esName: String =_
  @BeanProperty var hbaseZk: String =_
  @BeanProperty var hbaseFamily : String = _
  @BeanProperty var hbaseFillCurrentHour : Boolean = false
  @BeanProperty var model : String = _
  @BeanProperty var  fields: util.List[Field] = _
}
